package com.celeritymq.monitor;

import com.celeritymq.message.CelerityMessage;

public interface Monitor {

	void process(CelerityMessage msg);

	CelerityMessage monitor() throws InterruptedException;

	void startMonitor();

	void stopMonitor();

}
